let express = require("express");
// 引入第三方模块儿 nodejs-websocket 用来搭建websocket服务
let ws = require("nodejs-websocket");
console.log(ws)
// 创建soket服务
let server = ws.createServer((connect)=>{
    console.log('有新用户连接')
    // 监听客户端发送的消息
    connect.on("text",function(data){
        // console.log("客户端发送过来的消息："+data)
        console.log(data)
        // 将客户端消息广播给所有浏览器
        sendAll(data);
        // connect.sendText(data)
        // connect.sendText(data)
    })
    connect.on("colose",()=>{
        console.log("连接关闭")
    })
    connect.on("error",()=>{
        console.log("连接异常")
    })
})
function sendAll(data){
    // console.log()
    server.connections.forEach((connect)=>{
        connect.sendText(data)
    })
}
// 启动soket 服务
server.listen(9002)
let web = express();
web.use(express.static("public"));
web.listen(9001,()=>{
    console.log("服务端已启动...")
})